package com.example.mqtt_mode.mqtt.generator.service.impl;

import com.example.mqtt_mode.mqtt.config.MqttConfig;
import com.example.mqtt_mode.mqtt.generator.service.PublishMessageService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

/**
 * @author IT空门_门主
 * @date 2024/1/8
 */
@Slf4j
@Service
public class PublishMessageServiceImpl implements PublishMessageService  {

    @Override
    public void publishMessage(String message) {
        MqttConfig mqttConfig = new MqttConfig();
        mqttConfig.publishMQTT(message);
        log.info("发布消息中========>");
        log.info("发布消息: {}",message);
    }
}
